package com.axxc.jpa.task.rabbitmsg.provider;

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;

/**
 * @ClassName: RabbitMqStringMsgProviderTask
 * @Description: Fanout 就是我们熟悉的广播模式或者订阅模式，给Fanout转发器发送消息，绑定了这个转发器的所有队列都收到这个消息。
 *               这里使用三个队列来测试（也就是在 {@link com.axxc.jpa.config.RabbitMqConfig}
 *               类中创建和绑定的fanout.A、fanout.B、fanout.C）
 *               这三个队列都和Application中创建的fanoutExchange转发器绑定
 * @author xxc
 * @date 2018年8月3日 下午3:27:26
 * @see com.axxc.jpa.config.RabbitMqConfig
 */
//@Component
public class RabbitMqFanoutExchangeMsgProviderTask {

	@Autowired
	private AmqpTemplate rabbitTemplate;

	@Async
	@Scheduled(cron = "0/15 * * * * *") // 每十五秒
	public void reportCurrentTime() {
		this.rabbitTemplate.convertAndSend("fanoutExchange", "abcd.ee", "ccccccccccccccccccc");
	}
}
